package com.example.rabbitmq.consumer;

import com.rabbitmq.client.Channel;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.util.Date;


/**
 * @Date 2021/7/19 16:39
 * @Created by wangle
 * @Description
 */

@Slf4j
@Component
public class DeadLetterConsumer {
        //接受消息
        @RabbitListener(queues = "QD")
        public void  receiverD(Message message, Channel channel) throws  Exception{

            String msg=new String(message.getBody());
            log.info("当前时间{}：收到死信队列的消息{}",new Date().toString(),msg);


        }

}
